google.golang.org/grpc.addrConnStream.transportStream (field)
14 uses
google.golang.org/grpc (current package)
stream.go#L1364: as.transportStream = s
stream.go#L1391: transportStream *transport.ClientStream
stream.go#L1416: m, err := as.transportStream.Header()
stream.go#L1424: return as.transportStream.Trailer()
stream.go#L1434: as.transportStream.Write(nil, nil, &transport.WriteOptions{Last: true})
stream.go#L1443: return as.transportStream.Context()
stream.go#L1484: if err := as.transportStream.Write(hdr, payload, &transport.WriteOptions{Last: !as.desc.ClientStreams}); err != nil {
stream.go#L1507: if ct := as.transportStream.RecvCompress(); ct != "" && ct != encoding.Identity {
stream.go#L1525: if err := recv(&as.parser, as.codec, as.transportStream, as.decompressorV0, m, *as.callInfo.maxReceiveMessageSize, nil, as.decompressorV1, false); err != nil {
stream.go#L1527: if statusErr := as.transportStream.Status().Err(); statusErr != nil {
stream.go#L1547: if err := recv(&as.parser, as.codec, as.transportStream, as.decompressorV0, m, *as.callInfo.maxReceiveMessageSize, nil, as.decompressorV1, false); err == io.EOF {
stream.go#L1548: return as.transportStream.Status().Err() // non-server streaming Recv returns nil on success
stream.go#L1566: if as.transportStream != nil {
stream.go#L1567: as.transportStream.Close(err)